I/O Multiplexing হলো একটি প্রক্রিয়া, যা একাধিক I/O চ্যানেল (যেমন: Socket, ফাইল ডেসক্রিপ্টর) পর্যবেক্ষণ এবং একসাথে পরিচালনা করতে ব্যবহৃত হয়। এটি একাধিক I/O অপারেশন সমান্তরালে সম্পন্ন করে, যাতে একটি প্রোগ্রাম একাধিক Socket-এ বা ফাইল ডেসক্রিপ্টরে I/O ইভেন্টের জন্য অপেক্ষা করতে পারে এবং যেই Socket বা ফাইল ডেসক্রিপ্টর প্রস্তুত (Ready) হয়, সেই অনুযায়ী কাজ করে। I/O Multiplexing সাধারণত select(), poll(), এবং epoll() এর মতো সিস্টেম কল ব্যবহার করে বাস্তবায়িত হয়।

I/O Multiplexing এর ধারণা

I/O Multiplexing এমন একটি পদ্ধতি, যেখানে একটি প্রোগ্রাম একাধিক I/O চ্যানেলকে পর্যবেক্ষণ করতে পারে এবং যেই চ্যানেল প্রস্তুত হয় (যেমন: ডেটা পাঠানো বা গ্রহণ করার জন্য), সেই অনুযায়ী অপারেশন সম্পন্ন করে। এটি বিশেষত নেটওয়ার্ক প্রোগ্রামিং এবং সার্ভার ডিজাইনে ব্যবহৃত হয়, যেখানে একাধিক ক্লায়েন্ট সংযোগ সমান্তরালে পরিচালনা করতে হয়।

• Non-Blocking I/O:
  • I/O Multiplexing Non-Blocking I/O হিসেবে কাজ করে, যেখানে একটি প্রোগ্রাম একাধিক Socket বা ফাইল ডেসক্রিপ্টরে I/O ইভেন্টের জন্য অপেক্ষা করতে পারে, কিন্তু যখন একটি Socket বা চ্যানেল প্রস্তুত নয়, তখন এটি ব্লক না হয়ে অন্যান্য কাজ করতে পারে।
• Event-Driven Architecture:
  • I/O Multiplexing ইভেন্ট-ড্রিভেন আর্কিটেকচার ভিত্তিক, যেখানে একটি প্রোগ্রাম ইভেন্টগুলো (যেমন: ডেটা পাওয়া, নতুন সংযোগ) অনুযায়ী প্রতিক্রিয়া করে। এটি থ্রেড বা প্রসেস তৈরি না করেই কনকারেন্ট সংযোগ পরিচালনা করে, যা রিসোর্স ব্যবহার কমায় এবং পারফরম্যান্স বাড়ায়।

I/O Multiplexing এর প্রয়োজনীয়তা

I/O Multiplexing ব্যবহারের প্রধান কারণ হলো একাধিক I/O চ্যানেল বা সংযোগ একসাথে পরিচালনা করা। এটি বিশেষ করে নেটওয়ার্ক সার্ভার এবং বড় স্কেল অ্যাপ্লিকেশনগুলোতে অপরিহার্য, যেখানে একাধিক ক্লায়েন্ট সংযোগ বা ডেটা অপারেশন সমান্তরালে পরিচালনা করতে হয়। নিচে I/O Multiplexing এর প্রয়োজনীয়তা নিয়ে আলোচনা করা হলো:

Concurrency এবং Scalability:

• I/O Multiplexing একাধিক সংযোগ এবং ইভেন্ট একসাথে পরিচালনা করে কনকারেন্সি বাড়ায়। এটি সার্ভারগুলোর জন্য অত্যন্ত গুরুত্বপূর্ণ, কারণ সার্ভারগুলোতে একসাথে অনেক ক্লায়েন্ট সংযোগ করতে পারে।
• Traditional Thread বা Process-based মডেলের তুলনায় এটি অনেক বেশি স্কেলেবল। কারণ, প্রতিটি নতুন সংযোগের জন্য আলাদা থ্রেড তৈরি না করে, একক ইভেন্ট লুপের মাধ্যমে সমস্ত সংযোগ পরিচালনা করা হয়।

Resource Efficiency:

• থ্রেড বা প্রসেস ব্যবহারের তুলনায় I/O Multiplexing কম মেমরি এবং কম CPU ব্যবহার করে।
• প্রতিটি নতুন সংযোগের জন্য আলাদা প্রসেস বা থ্রেড তৈরি করলে রিসোর্স ব্যবহারের পরিমাণ বেড়ে যায়। কিন্তু I/O Multiplexing একই প্রক্রিয়ার মধ্যে সমস্ত সংযোগ পরিচালনা করতে পারে, যা সার্ভারের ওভারহেড কমায় এবং রিসোর্স সাশ্রয় করে।

Low Latency:

• Non-Blocking এবং Asynchronous Operation ব্যবহারের মাধ্যমে I/O Multiplexing লেটেন্সি কমায় এবং প্রোগ্রাম দ্রুত প্রতিক্রিয়া জানাতে পারে।
• এটি উচ্চ-পারফরম্যান্স এবং রিয়েল-টাইম অ্যাপ্লিকেশনগুলোর জন্য বিশেষভাবে উপযোগী।

Event-Driven Programming Support:

• I/O Multiplexing ইভেন্ট-ড্রিভেন প্রোগ্রামিং মডেলকে সমর্থন করে, যেখানে একটি ইভেন্ট লুপ সমস্ত ইভেন্ট (যেমন: নতুন সংযোগ, ডেটা পাওয়া, সংযোগ বন্ধ) পরিচালনা করে। এটি কোড সরল এবং সুনির্দিষ্ট করে তোলে এবং ডিবাগিং সহজ করে।

Non-Blocking I/O অপারেশন:

• Non-Blocking Mode-এ কাজ করে I/O Multiplexing নিশ্চিত করে যে কোনো Socket বা ফাইল ডেসক্রিপ্টর থেকে ডেটা পাওয়ার সময় প্রোগ্রাম ব্লক হবে না। এটি সার্ভার অ্যাপ্লিকেশনে প্রয়োজনীয়, কারণ সার্ভারকে একাধিক ক্লায়েন্টের জন্য প্রতিক্রিয়াশীল হতে হয়।

I/O Multiplexing এর প্রধান সিস্টেম কল

I/O Multiplexing সাধারণত তিনটি প্রধান সিস্টেম কলের মাধ্যমে পরিচালিত হয়:

select():

• এটি প্রাচীনতম এবং সাধারণ I/O Multiplexing সিস্টেম কল, যা একাধিক ফাইল ডেসক্রিপ্টর (FD) পর্যবেক্ষণ করে এবং যেই ফাইল ডেসক্রিপ্টর প্রস্তুত হয়, সেটির উপর I/O অপারেশন করে।
• এর সীমাবদ্ধতা হলো, এটি একবারে একটি নির্দিষ্ট সংখ্যক ফাইল ডেসক্রিপ্টর (1024) পর্যবেক্ষণ করতে পারে এবং বড় স্কেল অ্যাপ্লিকেশনে এটি কম কার্যকর।

poll():

• select()-এর একটি আধুনিক সংস্করণ, যা একাধিক ফাইল ডেসক্রিপ্টর একসাথে পর্যবেক্ষণ করতে পারে। এটি select()-এর কিছু সীমাবদ্ধতা দূর করে এবং ফাইল ডেসক্রিপ্টরগুলোর সাথে যুক্ত ইভেন্টগুলো পরিচালনা করে।
• তবে, অনেক ফাইল ডেসক্রিপ্টর একসাথে পরিচালনা করার সময় এটি এখনও অনেক CPU এবং মেমরি ব্যবহার করতে পারে।

epoll() (Linux-specific):

• Linux-এ epoll() ব্যবহার করা হয়, যা select() এবং poll()-এর তুলনায় অনেক বেশি কার্যকর এবং স্কেলেবল। এটি একাধিক সংযোগ পর্যবেক্ষণ করতে খুব কম CPU এবং মেমরি ব্যবহার করে এবং বড় স্কেল অ্যাপ্লিকেশনের জন্য উপযোগী।
• এটি ইভেন্ট-ড্রিভেন প্রোগ্রামিংয়ে বিশেষভাবে কার্যকর এবং উচ্চ-পারফরম্যান্স নেটওয়ার্ক অ্যাপ্লিকেশন তৈরি করতে ব্যবহৃত হয়।

I/O Multiplexing এর উদাহরণ

নিচে একটি সাধারণ উদাহরণ দেখানো হয়েছে, যেখানে Python ব্যবহার করে select() ফাংশনের মাধ্যমে I/O Multiplexing করা হয়েছে:

import select
import socket

# একটি TCP Socket তৈরি করা
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.bind(('localhost', 8080))
server_socket.listen(5)
server_socket.setblocking(False)

# ফাইল ডেসক্রিপ্টরগুলোর তালিকা
sockets_list = [server_socket]

print("Server is listening on port 8080...")

while True:
    # select() ব্যবহার করে I/O Multiplexing
    read_sockets, _, _ = select.select(sockets_list, [], [])

    for notified_socket in read_sockets:
        if notified_socket == server_socket:
            # নতুন সংযোগ গ্রহণ করা
            client_socket, client_address = server_socket.accept()
            client_socket.setblocking(False)
            sockets_list.append(client_socket)
            print(f"Accepted new connection from {client_address}")
        else:
            # ক্লায়েন্ট থেকে ডেটা পড়া
            data = notified_socket.recv(1024)
            if not data:
                print("Connection closed.")
                sockets_list.remove(notified_socket)
                notified_socket.close()
            else:
                print(f"Received data: {data.decode()}")

• ব্যাখ্যা:
  • এখানে একটি TCP সার্ভার তৈরি করা হয়েছে, যা একাধিক ক্লায়েন্টের সংযোগ গ্রহণ করতে সক্ষম।
  • select() ব্যবহার করে একাধিক Socket পর্যবেক্ষণ করা হচ্ছে, এবং কোন Socket-এ নতুন ডেটা পাওয়া গেলে বা সংযোগ তৈরি হলে সেই অনুযায়ী কাজ করা হচ্ছে।